package wodegua.d29_多线程;

import java.util.ArrayList;
import java.util.List;

/**
 * 什么是线程通信?
 * 当多个线程共同操作共享的资源时，线程间通过某种方式互相告知自己的状态，以相互协调，并避免无效的资源争夺。
 *
 * 线程通信的常见模型(生产者与消费者模型)
 * 1.生产者线程负责生产数据
 * 2.消费者线程负责消费生产者生产的数据。
 * 注意:生产者生产完数据应该等待自己，通知消费者消费;消费者消费完数据也应该等待自己，再通知生产者生产!
 *
 * Object类的等待和唤醒方法:
 * 方法名称
 * void wait()      让当前线程等待并释放所占锁，直到另一个线程调用notify()方法或 notifyAll()方法
 * void notify()    唤醒正在等待的单个线程
 * void notifyAll() 唤醒正在等待的所有线程
 * 注意:上述方法应该使用当前同步锁对象进行调用。
 */
public class d6_thread_communication {
    public static void main(String[] args) {
        //需求:3个生产者线程，负责生产包子，每个线程每次只能生产1个包子放在桌子
        //2个消费者线程负责吃包子，每人每次只能从桌子上拿1个包子吃。
        Desk desk = new Desk();
        new Thread(() -> {
            while (true) {
                desk.put();
            }
        }, "师傅1").start();
        new Thread(() -> {
            while (true) {
                desk.put();
            }
        }, "师傅2").start();
        new Thread(() -> {
            while (true) {
                desk.put();
            }
        }, "师傅3").start();

        new Thread(() -> {
            while (true) {
                desk.get();
            }
        }, "吃货1").start();
        new Thread(() -> {
            while (true) {
                desk.get();
            }
        }, "吃货2").start();
    }
}

class Desk{
    private static final List<String> list = new ArrayList<>();
    public synchronized void put(){
        String name = Thread.currentThread().getName();
        try {
            if (list.size() == 0) {
                System.out.println(name + "做了包子");
                list.add(name+"做的包子");
                Thread.sleep(2000);
            }
            this.notifyAll();
            this.wait();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    public synchronized void get(){
        String name = Thread.currentThread().getName();
        try {
            if (list.size() == 1) {
                System.out.println(name + "吃了" + list.get(0) + "包子");
                list.clear();
                Thread.sleep(1000);
            }
            this.notifyAll();
            this.wait();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}
